pyspark realtime scenarios